package com.chen.rocker;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.MessageChannel;

/**
 * @Author: chen
 * @Date: 2021/5/24 3:25 PM
 * @Version 1.0
 */
public interface Sink {

    /**
     * 创建一个名称是order.in 的消息管道
     * @return
     */
    @Input("order_in")
    public MessageChannel messageChannel() ;

}
